package mundo;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.MulticastSocket;

public class ThreadRecibirMensajeMulticast extends Thread 
{
	private MulticastSocket socket;
	private P2P aplicacion;
	
	public ThreadRecibirMensajeMulticast( MulticastSocket socket1, P2P aplicacion1 )
	{
		socket = socket1;
		aplicacion = aplicacion1;
	}
	
	public void run( )
	{
		while( true )
		{
			try {
				byte[] buf = new byte[ 1000 ];
				DatagramPacket paquete = new DatagramPacket( buf, buf.length );
				socket.receive( paquete );
				aplicacion.procesarMensajeMulticast( new String( buf ) );
			} catch (IOException e) {
				System.out.println( e.getMessage() );
			}
		}
	}

}
